Spring

#Spring| 来源: 网络整理| 查看: 265

Quartz对任务调度领域进行了高度抽象，抽象出了调度器，触发器，任务。简单介绍下几个组件的意思，具体起什么作用 Job：是一个接口，只有一个excute()，定义需要执行的任务，运行时的信息保存在JobDataMap中。 Trigger：描述触发job执行时间的触发规则。主要有SimpleTrigger和CronTrigger。 JobDetail：保存了Job的名称，描述，关联监听器等信息。 Calendar：特定时间点的集合 Scheduler：代表一个Quartz的独立容器，Trigger和JobDetail需要注册到Scheduler中。 ThreadPool：任务运行的基础设施。

简易demo

import org.quartz.Job; import org.quartz.JobExecutionContext; import org.quartz.JobExecutionException; import java.util.Date; public class SimpleJob implements Job { @Override public void execute(JobExecutionContext jobCtx) throws JobExecutionException { System.out.println(jobCtx.getTrigger().getName() + " triggered. time is:" + (new Date())); } }

使用Trigger

import org.quartz.JobDetail; import org.quartz.Scheduler; import org.quartz.SchedulerFactory; import org.quartz.SimpleTrigger; import org.quartz.impl.StdSchedulerFactory; import java.util.Date; public class SimpleTriggerRunner { public static void main(String args[]) { try { JobDetail jobDetail = new JobDetail("job1_1", "jgroup1", SimpleJob.class); SimpleTrigger simpleTrigger = new SimpleTrigger("trigger1_1", "tgroup1"); simpleTrigger.setStartTime(new Date()); simpleTrigger.setRepeatInterval(2000); simpleTrigger.setRepeatCount(100); SchedulerFactory schedulerFactory = new StdSchedulerFactory(); Scheduler scheduler = schedulerFactory.getScheduler(); scheduler.scheduleJob(jobDetail, simpleTrigger); scheduler.start(); } catch (Exception e) { e.printStackTrace(); } } }

使用Calendar：

import org.quartz.*; import org.quartz.impl.StdSchedulerFactory; import org.quartz.impl.calendar.AnnualCalendar; import java.util.Calendar; import java.util.Date; import java.util.GregorianCalendar; public class CalendarExample { public static void main(String[] args) throws Exception { SchedulerFactory sf = new StdSchedulerFactory(); Scheduler scheduler = sf.getScheduler(); AnnualCalendar holidays = new AnnualCalendar(); //五一劳动节 Calendar laborDay = new GregorianCalendar(); laborDay.add(Calendar.MONTH,5); laborDay.add(Calendar.DATE,1); holidays.setDayExcluded(laborDay, true); //国庆节 Calendar nationalDay = new GregorianCalendar(); nationalDay.add(Calendar.MONTH,10); nationalDay.add(Calendar.DATE,1); holidays.setDayExcluded(nationalDay, true); scheduler.addCalendar("holidays", holidays, false, false); //从5月1号10am开始 Date runDate = TriggerUtils.getDateOf(0,0, 10, 1, 5); JobDetail job = new JobDetail("job1", "group1", SimpleJob.class); SimpleTrigger trigger = new SimpleTrigger("trigger1", "group1", runDate, null, SimpleTrigger.REPEAT_INDEFINITELY, 60L * 60L * 1000L); //让Trigger遵守节日的规则（排除节日） trigger.setCalendarName("holidays"); scheduler.scheduleJob(job, trigger); scheduler.start(); try { // wait 30 seconds to show jobs Thread.sleep(30L * 1000L); // executing... } catch (Exception e) { } scheduler.shutdown(true); } }

【本文地址】

公司简介

联系我们